package com.quanyan.mq.client;


import com.quanyan.mq.client.reqeust.MqRequestMsg;
import com.quanyan.mq.client.response.MqResponse;

import javax.annotation.Nonnull;

/**
 * @Author Hugo.Wwg
 * @Since 2016-06-07 对外暴露服务接口
 */
public interface QcMsgClient<T> {

    /**
     * 同步发送
     */
    @Nonnull
    MqResponse syncSend(@Nonnull MqRequestMsg mqRequestMsg);

    /**
     * 异步发送
     */
    void asyncSend(@Nonnull MqRequestMsg mqRequestMsg);

}
